package com.linb.pan.stream.core;

import java.util.Map;

/**
 * 消息发送顶级接口
 */
public interface IStreamProducer {

    boolean sendMessage(String channelName, Object deploy);

    boolean sendMessage(String channelName, Object deploy, Map<String, Object> headers);

}
